package com.bw.gmall.retaltime.db.split.app;

import com.bw.gmall.realtime.commom.base.BaseApp;
import com.bw.gmall.realtime.commom.constant.Constant;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class DwdBaseLog extends BaseApp {
    @Override
    public void handle(StreamExecutionEnvironment env, DataStreamSource<String> dataStreamSource) {

    }
}
